446e2537895c15b404a74107069a12f3fc404b15,test/pig/org/apache/cassandra/pig/ThriftColumnFamilyTest.java,ThriftColumnFamilyTest,testCassandraStorageJoin,#,500
Before Change
public void testCassandraStorageJoin() throws IOException
{
//test key types with a join
pig.registerQuery("U8 = load 'cassandra://thrift_ks/u8?" + defaultParameters + "' using CassandraStorage();");
pig.registerQuery("Bytes = load 'cassandra://thrift_ks/bytes?" + defaultParameters + "' using CassandraStorage();");
//cast key to chararray
After Change
{
//test key types with a join
pig.registerQuery("U8 = load 'cql://thrift_ks/u8?" + defaultParameters + nativeParameters + "&input_cql=select%20*%20from%20u8%20where%20token(key)%20%3E%20%3F%20and%20token(key)%20%3C%3D%20%3F' using CqlNativeStorage();");
pig.registerQuery("Bytes = load 'cql://thrift_ks/bytes?" + defaultParameters + nativeParameters + "&input_cql=select%20*%20from%20bytes%20where%20token(key)%20%3E%20%3F%20and%20token(key)%20%3C%3D%20%3F' using CqlNativeStorage();");
//cast key to chararray
pig.registerQuery("b = foreach Bytes generate (chararray)key, column1, value;");